﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Data.SqlClient;
using System.Data;

namespace ankietyzacja.Dao
{
    public class AnkietaDao : Dao
    {


        public AnkietaDao(SqlConnection c, SqlTransaction t)
            : base(c, t)
        {
        }


        public DataTable loadPytaniaWAnkiecie(Int32 ankietaId)
        {
            String sql =
          " SELECT ANKIETA_ID, PYTANIEWANKIECIE_ID, TRESCPYTANIA, TYPODPOWIEDZI_ID, NUMERKOLEJNY " +
          " FROM PYTANIEWANKIECIE " +
          " WHERE ANKIETA_ID = @ANKIETA_ID " +
          " ORDER BY NUMERKOLEJNY";
            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));

            DataTable dataTable = new DataTable();
            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;


        }



        public DataTable loadOdpowiedziNaPytanie(Int32 pytanieWAnkiecieId)
        {

            String sql =
          " SELECT ODPOWIEDZNAPYTANIE_ID, PYTANIEWANKIECIE_ID, TRESCODPOWIEDZI, NUMERKOLEJNY  " +
          " FROM ODPOWIEDZNAPYTANIE " +
          " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID " +
          " ORDER BY NUMERKOLEJNY ";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));


            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;


        }


        public DataTable loadWypelnionaAnkieta(Int32 ankietaId, String uzytkownikId)
        {

            String sql =
          " SELECT WYPELNIONAANKIETA_ID ,DATAWYPELNIENIA, UZYTKOWNIK_ID, ANKIETA_ID " +
          " FROM WYPELNIONAANKIETA " +
          " WHERE ANKIETA_ID = @ANKIETA_ID " +
          "   AND UZYTKOWNIK_ID = @UZYTKOWNIK_ID ";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));
            command.Parameters.Add(new SqlParameter("@UZYTKOWNIK_ID", uzytkownikId));


            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;

        }


        public DataTable loadAnkieta(Int32 ankietaId)
        {


            String sql =
    " SELECT ANKIETA_ID, CZASZYCIA " +
    " FROM ANKIETA " +
    " WHERE ANKIETA_ID = @ANKIETA_ID " +
    "   AND CZYWZORZEC = 0";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));

            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;
        }



        public DataTable loadOdpowiedzDowolna(Int32 pytanieWAnkiecieId)
        {


            String sql =
    " SELECT ODPOWIEDZDOWOLNA_ID, PYTANIEWANKIECIE_ID, NAGLOWEKODPOWIEDZIDOWOLNEJ  " +
    " FROM ODPOWIEDZDOWOLNA " +
    " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));


            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;

        }


        public DataTable loadWyslanaAnkieta(Int32 ankietaId, String uzytkownikId)
        {

            String sql =
         @" SELECT w.*
          FROM WYSLANAANKIETA w, WYSLANAANKIETA_X_UZYTKOWNIK wu
         WHERE w.WYSLANAANKIETA_ID = wu.WYSLANAANKIETA_ID  
           AND w.ANKIETA_ID = @ANKIETA_ID
           AND wu.UZYTKOWNIK_ID = @UZYTKOWNIK_ID ";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));
            command.Parameters.Add(new SqlParameter("@UZYTKOWNIK_ID", uzytkownikId));

            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;


        }

        public Int32 InsertWynikAnkiety(Int32 ankietaId)
        {

            String sql =
           " INSERT INTO WYNIKANKIETY " +
           " (ANKIETA_ID)" +
          " VALUES " +
           " (@ANKIETA_ID); " +
           " SELECT scope_identity();";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));

            return System.Convert.ToInt32(command.ExecuteScalar());


        }

        public Int32 InsertWybranaOdpowiedz(Int32 wynikAnkietyId, Int32 odpowiedzNaPytanieId, Int32 wybranaOdpowiedz)
        {
            String InsertWybranaOdpowiedzSql =
          " INSERT INTO WYBRANAODPOWIEDZ " +
          " (ODPOWIEDZNAPYTANIE_ID, " +
          " WYNIKANKIETY_ID, " +
          " WYBRANAODPOWIEDZ)" +
         " VALUES " +
          " (@ODPOWIEDZNAPYTANIE_ID, " +
          " @WYNIKANKIETY_ID, " +
          " @WYBRANAODPOWIEDZ)";

            SqlCommand InsertWybranaOdpowiedzCommand = new SqlCommand(InsertWybranaOdpowiedzSql, connection, transaction);

            InsertWybranaOdpowiedzCommand.Parameters.Clear();
            InsertWybranaOdpowiedzCommand.Parameters.Add(new SqlParameter("@WYNIKANKIETY_ID", wynikAnkietyId));
            InsertWybranaOdpowiedzCommand.Parameters.Add(new SqlParameter("@ODPOWIEDZNAPYTANIE_ID", odpowiedzNaPytanieId));
            InsertWybranaOdpowiedzCommand.Parameters.Add(new SqlParameter("@WYBRANAODPOWIEDZ", wybranaOdpowiedz));

            return InsertWybranaOdpowiedzCommand.ExecuteNonQuery();

        }


        public Int32 InsertWpisanaOdpowiedzDowolna(Int32 wynikAnkietyId, Int32 odpowiedzDowolnaId, String odpowiedzDowolna)
        {

            String InsertWpisanaOdpowiedzDowolnaSql =
  @" INSERT INTO WPISANAODPOWIEDZDOWOLNA 
           (ODPOWIEDZDOWOLNA_ID
           ,WYNIKANKIETY_ID
           ,TRESCODPOWIEDZI)
     VALUES
           (@ODPOWIEDZDOWOLNA_ID
           ,@WYNIKANKIETY_ID
           ,@TRESCODPOWIEDZI)";

            SqlCommand InsertWpisanaOdpowiedzDowolnaCommand = new SqlCommand(InsertWpisanaOdpowiedzDowolnaSql, connection, transaction);


            InsertWpisanaOdpowiedzDowolnaCommand.Parameters.Clear();
            InsertWpisanaOdpowiedzDowolnaCommand.Parameters.Add(new SqlParameter("@WYNIKANKIETY_ID", wynikAnkietyId));
            InsertWpisanaOdpowiedzDowolnaCommand.Parameters.Add(new SqlParameter("@ODPOWIEDZDOWOLNA_ID", odpowiedzDowolnaId));
            InsertWpisanaOdpowiedzDowolnaCommand.Parameters.Add(new SqlParameter("@TRESCODPOWIEDZI", odpowiedzDowolna));

            return InsertWpisanaOdpowiedzDowolnaCommand.ExecuteNonQuery();
        }



        public Int32 InsertWypelnionaAnkieta(Int32 ankietaId, String uzytkownikId)
        {


            String sql =
                @"INSERT INTO WYPELNIONAANKIETA
           (DATAWYPELNIENIA
           ,UZYTKOWNIK_ID
           ,ANKIETA_ID)
     VALUES
           (GETDATE()
           ,@UZYTKOWNIK_ID
           ,@ANKIETA_ID)";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));
            command.Parameters.Add(new SqlParameter("@UZYTKOWNIK_ID", uzytkownikId));

            return command.ExecuteNonQuery();




        }

        public Int32 updateOdpowiedzDowolna(String naglowekOdpowiedziDowolnej, Int32 pytanieWAnkiecieId)
        {


            String sql =
         "UPDATE ODPOWIEDZDOWOLNA " +
         " SET NAGLOWEKODPOWIEDZIDOWOLNEJ = @NAGLOWEKODPOWIEDZIDOWOLNEJ " +
         " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@NAGLOWEKODPOWIEDZIDOWOLNEJ", naglowekOdpowiedziDowolnej));
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));

            return command.ExecuteNonQuery();

        }

        public Int32 insertOdpowiedzDowolna(String naglowekOdpowiedziDowolnej, Int32 pytanieWAnkiecieId)
        {


            String sql =
             "INSERT INTO ODPOWIEDZDOWOLNA " +
             "   (PYTANIEWANKIECIE_ID,  NAGLOWEKODPOWIEDZIDOWOLNEJ) " +
             " VALUES (@PYTANIEWANKIECIE_ID, @NAGLOWEKODPOWIEDZIDOWOLNEJ) ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@NAGLOWEKODPOWIEDZIDOWOLNEJ", naglowekOdpowiedziDowolnej));
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));

            return command.ExecuteNonQuery();

        }

        public DataTable loadOdpowiedz(Int32 odpowiedzNaPytanieId)
        {
            String sql = "SELECT * " +
                  "  FROM ODPOWIEDZNAPYTANIE " +
                  " WHERE ODPOWIEDZNAPYTANIE_ID = @ODPOWIEDZNAPYTANIE_ID ";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ODPOWIEDZNAPYTANIE_ID", odpowiedzNaPytanieId));
            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;


        }


        public DataTable loadNastepnaOdpowiedz(Int32 pytanieWAnkiecieId, Int32 numerKolejny)
        {

            String sql =
           "SELECT * " +
           "  FROM ODPOWIEDZNAPYTANIE O " +
           " WHERE O.PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID " +
           "   AND O.NUMERKOLEJNY = (SELECT MIN(O2.NUMERKOLEJNY) " +
           "                           FROM ODPOWIEDZNAPYTANIE O2 " +
           "                          WHERE O2.PYTANIEWANKIECIE_ID = O.PYTANIEWANKIECIE_ID " +
           "                            AND O2.NUMERKOLEJNY > @NUMERKOLEJNY )    ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));
            command.Parameters.Add(new SqlParameter("@NUMERKOLEJNY", numerKolejny));
            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;
        }

        public DataTable loadPoprzedniaOdpowiedz(Int32 pytanieWAnkiecieId, Int32 numerKolejny)
        {

            String sql =
                        "SELECT * " +
                        "  FROM ODPOWIEDZNAPYTANIE O " +
                        " WHERE O.PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID " +
                        "   AND O.NUMERKOLEJNY = (SELECT MAX(O2.NUMERKOLEJNY) " +
                        "                           FROM ODPOWIEDZNAPYTANIE O2 " +
                        "                          WHERE O2.PYTANIEWANKIECIE_ID = O.PYTANIEWANKIECIE_ID " +
                        "                            AND O2.NUMERKOLEJNY < @NUMERKOLEJNY )    ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));
            command.Parameters.Add(new SqlParameter("@NUMERKOLEJNY", numerKolejny));
            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;
        }

        public Int32 updateNumerKolejnyOdpowiedzi(Int32 odpowiedzNaPytanieId, Int32 numerKolejny)
        {
            String sql =
"UPDATE ODPOWIEDZNAPYTANIE " +
"   SET NUMERKOLEJNY = @NUMERKOLEJNY " +
" WHERE ODPOWIEDZNAPYTANIE_ID = @ODPOWIEDZNAPYTANIE_ID ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ODPOWIEDZNAPYTANIE_ID", odpowiedzNaPytanieId));
            command.Parameters.Add(new SqlParameter("@NUMERKOLEJNY", numerKolejny));

            return command.ExecuteNonQuery();



        }

        public DataTable loadPytanie(Int32 pytanieWAnkiecieId)
        {
            String sql = "SELECT * " +
                   "  FROM PYTANIEWANKIECIE " +
                   " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID ";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));
            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;


        }


        public DataTable loadNastepnePytanie(Int32 ankietaId, Int32 numerKolejny)
        {

            String sql =
                        "SELECT * " +
                        "  FROM PYTANIEWANKIECIE P " +
                        " WHERE P.ANKIETA_ID = @ANKIETA_ID " +
                        "   AND P.NUMERKOLEJNY = (SELECT MIN(P2.NUMERKOLEJNY) " +
                        "                           FROM PYTANIEWANKIECIE P2 " +
                        "                          WHERE P2.ANKIETA_ID = P.ANKIETA_ID " +
                        "                            AND P2.NUMERKOLEJNY > @NUMERKOLEJNY )    ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));
            command.Parameters.Add(new SqlParameter("@NUMERKOLEJNY", numerKolejny));
            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;
        }

        public DataTable loadPoprzedniePytanie(Int32 ankietaId, Int32 numerKolejny)
        {

            String sql =
                        "SELECT * " +
                        "  FROM PYTANIEWANKIECIE P " +
                        " WHERE P.ANKIETA_ID = @ANKIETA_ID " +
                        "   AND P.NUMERKOLEJNY = (SELECT MAX(P2.NUMERKOLEJNY) " +
                        "                           FROM PYTANIEWANKIECIE P2 " +
                        "                          WHERE P2.ANKIETA_ID = P.ANKIETA_ID " +
                        "                            AND P2.NUMERKOLEJNY < @NUMERKOLEJNY )    ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));
            command.Parameters.Add(new SqlParameter("@NUMERKOLEJNY", numerKolejny));
            DataTable dataTable = new DataTable();

            new SqlDataAdapter(command).Fill(dataTable);

            return dataTable;
        }



        public Int32 updateNumerKolejnyPytania(Int32 pytanieWAnkiecieId, Int32 numerKolejny)
        {
            String sql =
             "UPDATE PYTANIEWANKIECIE " +
             "   SET NUMERKOLEJNY = @NUMERKOLEJNY " +
             " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));
            command.Parameters.Add(new SqlParameter("@NUMERKOLEJNY", numerKolejny));

            return command.ExecuteNonQuery();



        }


        public Int32 copyAnkieta(Int32 ankietaId, DateTime czasZycia, Boolean czyWzorzec)
        {

            String sql =
         "   INSERT INTO ANKIETA " +
         "  ([NAZWAANKIETY] " +
         "  ,[CZASZYCIA] " +
         "  ,[DATAUTWORZENIA] " +
         "  ,[CZYWZORZEC] " +
         "  ,[OPIS] " +
         "  ,[NOTATKA]) " +
         " SELECT " +
         "   NAZWAANKIETY " +
         "  ,@CZASZYCIA " +
         "  ,GETDATE() " +
         "  ,@CZYWZORZEC " +
         "  ,OPIS " +
         "  ,NOTATKA " +
         " FROM ANKIETA " +
         " WHERE ANKIETA_ID = @ANKIETA_ID; " +
         " SELECT scope_identity(); ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));
            command.Parameters.Add(new SqlParameter("@CZYWZORZEC", czyWzorzec));
            command.Parameters.Add(new SqlParameter("@CZASZYCIA", czasZycia));

            return System.Convert.ToInt32(command.ExecuteScalar());

        }



        public Int32 copyPytanieWAnkiecie(Int32 ankietaIdNew, Int32 pytanieWAnkiecieId)
        {

            String sql =
          "   INSERT INTO PYTANIEWANKIECIE " +
          "  ([ANKIETA_ID] " +
          "  ,[TRESCPYTANIA] " +
          "  ,[TYPODPOWIEDZI_ID] " +
          "  ,[NUMERKOLEJNY]) " +
          " SELECT " +
          "   @ANKIETA_ID_NEW " +
          "  ,TRESCPYTANIA " +
          "  ,TYPODPOWIEDZI_ID " +
          "  ,NUMERKOLEJNY " +
          " FROM PYTANIEWANKIECIE " +
          " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID; " +
          " SELECT scope_identity(); ";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID_NEW", ankietaIdNew));
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));

            return System.Convert.ToInt32(command.ExecuteScalar());


        }



        public Int32 copyOdpowiedziNaPytanie(Int32 pytanieWAnkiecieIdNew, Int32 pytanieWAnkiecieId)
        {

            String sql =

          " INSERT INTO ODPOWIEDZNAPYTANIE " +
          " ([PYTANIEWANKIECIE_ID] " +
          " ,[TRESCODPOWIEDZI] " +
          " ,[NUMERKOLEJNY]) " +
          " SELECT  " +
          "  @PYTANIEWANKIECIE_ID_NEW " +
          " ,TRESCODPOWIEDZI " +
          " ,NUMERKOLEJNY " +
          " FROM ODPOWIEDZNAPYTANIE " +
          " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID_NEW", pytanieWAnkiecieIdNew));
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));

            return System.Convert.ToInt32(command.ExecuteScalar());


        }


        public Int32 copyOdpowiedzDowolna(Int32 pytanieWAnkiecieIdNew, Int32 pytanieWAnkiecieId)
        {

            String sql =

          " INSERT INTO ODPOWIEDZDOWOLNA " +
          " ([PYTANIEWANKIECIE_ID] " +
          " ,[NAGLOWEKODPOWIEDZIDOWOLNEJ]) " +
          " SELECT  " +
          "  @PYTANIEWANKIECIE_ID_NEW " +
          " ,NAGLOWEKODPOWIEDZIDOWOLNEJ " +
          " FROM ODPOWIEDZDOWOLNA " +
          " WHERE PYTANIEWANKIECIE_ID = @PYTANIEWANKIECIE_ID";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID_NEW", pytanieWAnkiecieIdNew));
            command.Parameters.Add(new SqlParameter("@PYTANIEWANKIECIE_ID", pytanieWAnkiecieId));

            return System.Convert.ToInt32(command.ExecuteScalar());


        }



        public Int32 insertAnkieta(String nazwaAnkiety)
        {
            String sql =
     "INSERT INTO ANKIETA" +
"(NAZWAANKIETY" +
",CZASZYCIA" +
",DATAUTWORZENIA" +
",CZYWZORZEC" +
",OPIS" +
",NOTATKA)" +
"VALUES" +
"(@NAZWAANKIETY" +
",null" +
",getdate()" +
",1" +
",null" +
",null); SELECT scope_identity();";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@NAZWAANKIETY", nazwaAnkiety));

            return System.Convert.ToInt32(command.ExecuteScalar());


        }


        public Int32 deleteOdpowiedzDowolnaForAnkieta(Int32 ankietaId)
        {
            String sql =
         "DELETE FROM ODPOWIEDZDOWOLNA" +
        " WHERE PYTANIEWANKIECIE_ID IN (SELECT PYTANIEWANKIECIE_ID" +
        " FROM PYTANIEWANKIECIE WHERE ANKIETA_ID = @ANKIETA_ID)";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));

            return command.ExecuteNonQuery();


        }

        public Int32 deleteOdpowiedzNaPytanieForAnkieta(Int32 ankietaId)
        {
            String sql =
            "DELETE FROM ODPOWIEDZNAPYTANIE" +
           " WHERE PYTANIEWANKIECIE_ID IN (SELECT PYTANIEWANKIECIE_ID" +
           " FROM PYTANIEWANKIECIE WHERE ANKIETA_ID = @ANKIETA_ID)";

            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));

            return command.ExecuteNonQuery();


        }

        public Int32 deletePytanieForAnkieta(Int32 ankietaId)
        {
            String sql =
            "DELETE FROM PYTANIEWANKIECIE" +
            " WHERE ANKIETA_ID = @ANKIETA_ID";


            SqlCommand command = new SqlCommand(sql, connection, transaction);
            command.Parameters.Add(new SqlParameter("@ANKIETA_ID", ankietaId));

            return command.ExecuteNonQuery();


        }



    }


}